package com.bfxy.disruptor.common.consume;

import com.bfxy.disruptor.common.RingBuffer;
import com.bfxy.disruptor.common.balance.Sequence;

public interface ConsumeFactory<T>
{
	EventConsumer createEventProcessor(RingBuffer<T> ringBuffer, Sequence[] barrierSequences);
}
